package com.bitters.pulsar.api;

import org.apache.pulsar.client.admin.PulsarAdmin;

import java.util.List;

/**
 * @description:
 * @author: thomas.he
 * @date: 2022/7/1
 */
public class CreateNamespaces {
    public static void main(String[] args) throws Exception {
        // 1- 创建Pulsar的Admin管理对象
        String serviceUrl = "http://10.18.60.12:6650";
        PulsarAdmin admin = PulsarAdmin.builder()
                .serviceHttpUrl(serviceUrl)
                .build();
        // 2- 创建名称空间
        //admin.namespaces().createNamespace("itcast_pulsar_t/itcast_pulsar_n");
        // 3- 获取所有的名称空间
        System.out.println("获取当前有那些名称空间:");
        List<String> namespaces = admin.namespaces().getNamespaces("my-namespace");
        for (String namespace : namespaces) {
            System.out.println(namespace);
        }
        // 4- 删除名称空间
        //admin.namespaces().deleteNamespace("itcast_pulsar_t/itcast_pulsar_n");
        // 6. 关闭资源
        admin.close();
    }
}
